package com.sikaryofficial.information.message.consumer;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.SubscribableChannel;

/**
 * input 消费者定义
 *
 *
 * @Description: MySink
 */
public interface MQConsumer {
    String BINDINGS_INFORMATION_SYNC_INPUT = "information-sync-input";

    @Input(BINDINGS_INFORMATION_SYNC_INPUT)
    SubscribableChannel attendInput();
}
